# -*- coding: UTF-8 -*-
"""
@File    ：main.py
@Author  ：techPang
@Date    ：2025/2/8 13:21 
@Version ：1.0
"""
from file_define import FileReader, TextFileReader, JsonFileReader
from data_define import Record
from pymysql import Connection

text_file_reader = TextFileReader("./2011年1月销售数据.txt")
json_file_reader = JsonFileReader("./2011年2月销售数据JSON.txt")

# 获取1、2月份的数据
jan_data: list[Record] = text_file_reader.read_date()
feb_data: list[Record] = json_file_reader.read_date()

# 合并两个月份的数据
all_data = jan_data + feb_data

# for data in all_data:
#     print(data)
#     print(type(data))

# 创建数据库连接对象
conn = Connection(
    host='47.93.99.194',
    port=3306,
    user='root',
    password='czt',
    database='py_sql',
    autocommit=True
)

# 创建游标对象
cursor = conn.cursor()

for record in all_data:
    # 组织sql语句
    sql = (f"insert into orders(order_date, order_id, money, province) "
           f"values('{record.date}', '{record.order_id}', '{record.money}','{record.province}')")
    # print(sql)
    # 执行sql
    cursor.execute(sql)

# 关闭连接
conn.close()
